package com.example.demo.queue;

import com.example.demo.entity.ChateMessageEntity;
import org.springframework.stereotype.Component;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

@Component
public class RedisChatMessageQueue {

    private static Map<String, ChateMessageEntity> messageEntityMap = new ConcurrentHashMap<>();

    public void put(String key, ChateMessageEntity message) {
        messageEntityMap.put(key, message);
    }
}
